package com.flink.cus.wdopers;

import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;

public class MaxMinFun3 extends ProcessWindowFunction <Tuple3<Long, Float, Long>, Tuple3<Long, Float, Long>, Long, TimeWindow> {

    @Override
    public void process(Long key,
            ProcessWindowFunction<Tuple3<Long, Float, Long>, Tuple3<Long, Float, Long>, Long, TimeWindow>.Context context,
            Iterable<Tuple3<Long, Float, Long>> elements, Collector<Tuple3<Long, Float, Long>> out) throws Exception {
     
        
    }

    
}
